package com.yfp.client.mqtt;

import com.yfp.common.mqtt.model.ChannelName;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Service;

/**
 * MQTT消息处理器（消费者）
 * 处理接收到的消息
 */
@Service
public class MqttService {

    @ServiceActivator(inputChannel = ChannelName.CHANNEL_NAME_IN)
    public void receiveMessage(Message<String> message) {

    }
}
